
package com.jf.cloud.live.task;


import com.jf.cloud.live.service.LiveProdStoreService;
import com.jf.cloud.live.service.LiveRoomService;
import com.jf.cloud.live.service.LiveUserService;
import com.xxl.job.core.handler.annotation.XxlJob;
import me.chanjar.weixin.common.error.WxErrorException;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;

/**
 * 直播的定时任务
 * @author zz
 */
@Component
public class LiveTask {

    @Autowired
    private LiveRoomService liveRoomService;
    @Autowired
    private LiveProdStoreService liveProdStoreService;
    @Autowired
    private LiveUserService liveUserService;

    private static final Logger log = LoggerFactory.getLogger(LiveTask.class);
    /**
     * 定时每分钟去同步微信的直播间接口
     */
    @XxlJob("synchronousWxLiveRoom")
    public void synchronousWxLiveRoom() throws WxErrorException {
        log.info("==============同步微信的直播间信息开始===================");

        liveRoomService.synchronousWxLiveRoom();

        log.info("==============同步微信的直播间信息结束===================");
    }

    /**
     * 定时每5分钟去同步微信的直播间商品接口
     */
    @XxlJob("synchronousWxLiveProds")
    public void synchronousWxLiveProds() throws WxErrorException {
        log.info("==============同步微信的直播商品开始===================");

        liveProdStoreService.synchronousWxLiveProds();

        log.info("==============同步微信的直播商品结束===================");
    }

    /**
     * 定时每分钟去同步微信的直播间接口
     */
    @XxlJob("offShelfLiveProds")
    public void offShelfLiveProds() throws WxErrorException {
        log.info("==============删除十天前上架的微信直播商品开始===================");

        liveProdStoreService.removeOldLiveProd();

        log.info("==============删除十天前上架的微信直播商品结束===================");
    }

    /**
     * 定时每5分钟去同步微信的直播间成员列表接口
     */
    @XxlJob("synchronousWxLiveUsers")
    public void synchronousWxLiveUsers() throws WxErrorException {
        log.info("==============同步微信的成员列表开始===================");

        liveUserService.synchronousWxLiveUsers();

        log.info("==============同步微信的成员列表结束===================");
    }
}
